package com.ruoyi.project.mq;

import lombok.extern.slf4j.Slf4j;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;

/**
 * 延迟队列方式1-消息发送者
 * @author:shengquan
 * @Date:2019/10/12 11:05
 */
/*@Component*/

@RestController
@RequestMapping("/front/test")
@Slf4j
public class DelaySenderOne {


    /**
     * 向延迟队列发送消息
     * 注意这里设置的是setExpiration，而不是delay。
     */
    @PostMapping("/mq")
    public void send(@RequestParam String msg,@RequestParam int delayTime) {

        DelaySender.send(msg,delayTime);
    }





}
